python - 我想要一个像redis pubsub中的kafka client_id这样的功能